package main

import (
	"log"
	"oceanlearn/lib/rabbitMQ"
)

func main() {

	simple := rabbitMQ.NewRabbitMQPubSub(rabbitMQ.MQURL, "dlx_exchange")
	simple.RecieveSub(Print2)
	defer simple.Destory()
}
func Print2(message []byte) bool {
	log.Printf("死信: %s", message)
	return true
}
